6b35d65b44a3a60d99492c8786854e7dd4634b1e,src/test/java/org/graylog/plugins/beats/BeatsCodecTest.java,BeatsCodecTest,decodeMessagesHandlesPacketbeatMessages,#,81

Before Change


        final RawMessage rawMessage = new RawMessage(json);
        final Collection<Message> messages = codec.decodeMessages(rawMessage);
        assertThat(messages)
                .isNotNull()
                .hasSize(1);
        final Message message = messages.iterator().next();
        assertThat(message.getSource()).isEqualTo("example.local");
        assertThat(message.getTimestamp()).isEqualTo(new DateTime(2016, 4, 1, 0, 0, DateTimeZone.UTC));

After Change


        final byte[] json = Resources.toByteArray(Resources.getResource("packetbeat-dns.json"));
        final RawMessage rawMessage = new RawMessage(json);
        final Message message = codec.decode(rawMessage);
        assertThat(message).isNotNull();
        assertThat(message.getSource()).isEqualTo("example.local");
        assertThat(message.getTimestamp()).isEqualTo(new DateTime(2016, 4, 1, 0, 0, DateTimeZone.UTC));
        assertThat(message.getField("facility")).isEqualTo("packetbeat");